package com.saic.bolt;

import java.util.Map;

import org.apache.commons.lang.StringUtils;
import org.apache.storm.task.OutputCollector;
import org.apache.storm.task.TopologyContext;
import org.apache.storm.topology.OutputFieldsDeclarer;
import org.apache.storm.topology.base.BaseRichBolt;
import org.apache.storm.tuple.Tuple;
import org.apache.storm.tuple.Values;

public class OtherBolt extends BaseRichBolt{

	/**
	 * 
	 */
	private static final long serialVersionUID = 7418661268934843858L;

	public void prepare(Map stormConf, TopologyContext context, OutputCollector collector) {
		
		// init hbaseEnv
		
	}

	public void execute(Tuple input) {
		String word = input.getString(0);
		if(!"{".equals(word) && !"}".equals(word)){
			if(StringUtils.isBlank(word)){
			return;
			}
		}
		System.out.println("------------------HbaseBolt--------------");
		System.out.println("word:"+word);
		//put data to other place
		
	}

	public void declareOutputFields(OutputFieldsDeclarer declarer) {
		// TODO Auto-generated method stub
		
	}

}
